package com.open.fei.listener;

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;

/**
 * 消费者
 * @author zhaoYuFei
 */
@RocketMQMessageListener(topic = "test-topic", consumerGroup = "MyConsumer")
public class MyConsumerListener implements RocketMQListener<String> {
    @Override
    public void onMessage(String message) {
        System.out.println("Received message: " + message);
        // 处理接收到的消息
    }
}
